//package com.course.configs;
//
//import com.alibaba.fastjson.JSONObject;
//import com.course.model.CourseOrder;
//import com.course.service.CourseOrderService;
//import com.course.service.RedisService;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//import org.thymeleaf.util.StringUtils;
//
//import java.util.Date;
//
//
///**
// * kafka消费者
// */
//@Component
//public class KafkaConsumer {
//    @Autowired
//    CourseOrderService courseOrderService;
//    @Autowired
//    RedisService redisService;
//    @KafkaListener(topics = {"test"})
//    public void receive(String message){
//        if(!StringUtils.isEmpty(message)){
//            JSONObject json = JSONObject.parseObject(message);
//            if(json != null && !json.isEmpty()){
//                CourseOrder co = courseOrderService.findByUserCourse(json.getInteger("userId"),json.getInteger("courseId"));
//                if(co == null){
//                    co = new CourseOrder(json.getInteger("courseId"),json.getInteger("userId"),new Date());
//                    courseOrderService.addOrUpdate(co);
//                }
//            }
//            System.out.println("消费消息:" + message);
//        }
//    }
//    /*@KafkaListener(topics = {"test"})
//    public void listen(ConsumerRecord<?, ?> record){
//
//        Optional<?> kafkaMessage = Optional.ofNullable(record.value());
//
//        if (kafkaMessage.isPresent()) {
//
//            Object message = kafkaMessage.get();
//            System.out.println("---->"+record);
//            System.out.println("---->"+message);
//
//        }
//
//    }*/
//}
//
